package org.huangrui.spark.scala.core.rdd.operate.transform

import org.apache.spark.{SparkConf, SparkContext}

/**
 * @Author hr
 * @Create 2024-10-17 19:43 
 */
object Spark13_Operate_Transform_KV_sortByKey {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setMaster("local[*]").setAppName("spark")
    val sc = new SparkContext(conf)
    val tuples = List(("a", 1), ("b", 3), ("a", 4), ("b", 2))
    // TODO sortByKey方法
    //      groupByKey  : 按照 K 对 V 进行分组
    //      reduceByKey : 按照 K 对 V 进行两两聚合
    //      sortByKey   : 按照 K 排序
    sc.parallelize(tuples,2).sortByKey().collect.foreach(println)

    sc.stop()
  }
}
